package com.my.study.service.Impl;

import com.my.study.consumer.service.ConsumerService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.springframework.stereotype.Service;

//@RocketMQMessageListener 注解用于配置一个消息监听器,它包含以下两个重要的参数
//topic:指定监听器要消费哪个主题的消息。一个主题可以有多个消费者组订阅。
//consumerGroup:指定监听器属于哪个消费者组。一个消费者组内的消费者会负责消费主题的一部分消息,实现负载均衡。
@Slf4j
@Service
@RocketMQMessageListener(consumerGroup = "base-rocketmq-server", topic = "role_producer_topic")
public class UserConsumerServiceImpl implements ConsumerService {

    @Override
    public void onMessage(String str) {
        log.info("收到角色信息,处理用户相关的角色数据:" + str);
    }

}
